package com.bdi.mqtt_broker.service;

import io.netty.channel.ChannelId;

/**
 * @author WangNing yogehaoren@gmial.com <br>
 * @since 1.0
 */
public interface ChannelManagerService {

    /**
     * 获取ChannelID
     * @param key 识别码 {brokerID}_{ChannelId.longText()}
     * @return ChannelId
     */
    ChannelId get(String key);

    /**
     * 存放 ChannelID
     * @param key 识别码
     * @param channelId ChannelId
     */
    void put(String key, ChannelId channelId);


    void remove(String key);


}
